package org.future.task.core.group;

import java.util.List;

public interface Group {

    void init();

    void  submit(String queueName);

    List<Object> receive(String queueName, int size, int timeOut);

    void sink(String queueName, List<Object> dataList) throws Exception;

}
